package top.shenluw.springdemo.kafka;

import org.slf4j.Logger;
import org.springframework.boot.autoconfigure.SpringBootApplication;
import org.springframework.kafka.annotation.KafkaListener;

import static org.slf4j.LoggerFactory.getLogger;

/**
 * @author Shenluw
 * created: 2020/5/2 21:32
 */
@SpringBootApplication
public class Application {
	private final static Logger log = getLogger(Application.class);

	@KafkaListener(topics = "topic0", groupId = "mytest")
	public void listen(String msg) {
		log.info("kafka msg: {}", msg);
	}

}
